package com.test.concurrent;

/**
 * @author: zhangzeli
 * @date 14:49 2018/4/26
 * <P></P>
 */
public class PstreamMain {
    public static void main(String[] args) {
        new Thread(new Plus()).start();
        new Thread(new Multiply()).start();
        new Thread(new Div()).start();

        for(int i =1 ;i<1000;i++){
            for (int j=1;j<1000;j++){
                Msg msg = new Msg();
                msg.i =i;
                msg.j = j;
                msg.orgStr="(("+i+"+"+j+")*"+i+")/2";
                Plus.bq.add(msg);
            }
        }
    }
}
